653d344b2808d997d57609207a001c596f5babda,core/src/main/java/io/undertow/channels/DetachableStreamSourceChannel.java,DetachableStreamSourceChannel,read,#ByteBuffer[]#number#number#,189
Before Change
}
public long read(final ByteBuffer[] dsts, final int offset, final int length) throws IOException {
if (isFinished() && minusOneReturned) {
return -1;
}
long ret = delegate.read(dsts, offset, length);
if (ret == -1) {
minusOneReturned = true;
} else if (isFinished()) {
runReadListener();
}
return ret;
}
public void wakeupReads() {
After Change
}
public long read(final ByteBuffer[] dsts, final int offset, final int length) throws IOException {
if (isFinished()) {
return -1;
}
return delegate.read(dsts, offset, length);
}
public void wakeupReads() {